package indi.zhifa.study2025.flinkcdc.redis.command;

import lombok.Getter;
import lombok.Setter;


public class RedisSinkCommand<T> {
    @Setter
    @Getter
    protected ERedisCommand command;

    @Setter
    @Getter
    protected long dua;

    @Setter
    @Getter
    protected  String key;
    @Setter
    @Getter
    protected  T value;


    public void initSet(String pKey, T pValue) {
        command = ERedisCommand.SET;
        dua = 300;
        key = pKey;
        value = pValue;
    }

    public void initDel(String pKey) {
        command = ERedisCommand.DEL;
        key = pKey;
    }

}
